@askprasanna I've made the spout default to an auto offset reset policy of "earliest" when the user requests the at-least-once processing guarantee. I think this addresses your request here https://issues.apache.org/jira/browse/STORM-2546?focusedCommentId=16152824&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16152824.

@srdo Awesome. Thanks for following up.

@srdo
I found same suggestion as my 2 cents is already discussed from JIRA issue. Is it already addressed?

@HeartSaVioR Yes, you are right. We set the auto offset reset policy to earliest by default when AT_LEAST_ONCE is picked if the user hasn't explicitly set anything else.

The misconfiguration I'm most worried about is where users set AT_LEAST_ONCE, and then forget to set the auto offset reset policy which defaults to latest, because it's an easy mistake to make if you're not already very familiar with Kafka's options. The other weird configurations (AT_LEAST_ONCE+latest, AT_MOST_ONCE+earliest) have to be explicitly chosen by the user.

I can't think of a reason why users would want to use those configurations, but I thought it might be better not to prevent the user from using those settings if they really want to, because there might be a use case I'm not seeing.

I'm happy to add in checks and error messages (or maybe even throwing exceptions) when using those configurations, if you think it makes sense?

@srdo
Sure. Makes sense. Let's add a warning message.

@HeartSaVioR Added the warning. Will squash and merge if the warning looks good.

@HeartSaVioR Merged to master. Yes, I'll put up a 1.x version tonight.